471938238e56b52e8291c537655092fd8bfe47c9,src/java/org/apache/cassandra/streaming/StreamInSession.java,StreamInSession,closeIfFinished,#,125

Before Change


                    assert sstable.getTableName().equals(table);

                    // Acquiring the reference (for secondary index building) before adding it makes sure we don't have to care about races
                    sstable.acquireReference();
                    referenced.add(sstable);

                    ColumnFamilyStore cfs = Table.open(sstable.getTableName()).getColumnFamilyStore(sstable.getColumnFamilyName());

After Change


                    assert sstable.getTableName().equals(table);

                    // Acquiring the reference (for secondary index building) before adding it makes sure we don't have to care about races
                    if (!sstable.acquireReference())
                        throw new RuntimeException("We shouldn't fail acquiring a reference on a sstable that has just been transfered");

                    referenced.add(sstable);